package com.imooc.kafka;

import org.apache.kafka.clients.admin.*;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.config.ConfigResource;
import org.apache.kafka.common.errors.TimeoutException;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.EnableKafka;

import java.util.*;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

@SpringBootApplication
@EnableKafka
public class ExamplesApplication {

	public static void main(String[] args)  {
		System.setProperty("java.security.auth.login.config", "D:/gitee/KafkaSimpleExample/src/main/resources/kafka_client_jaas.conf");
		SpringApplication.run(ExamplesApplication.class, args);
	}

}
